
package be.hogent.iii.project.newconnectie;

import java.net.InetAddress;

/**
 *
 * @author Dieter Van der Stock
 */
public class Connectie {
    Client client;
    Handler handler;
    
    public Connectie(String ip) {
        
        try {
            //we maken de client aan, die de verbinding met de server zal maken en verzenden/ontvangen zal verzorgen
            client = new Client(InetAddress.getByName(ip), 9090);
            Thread t = new Thread(client);
            t.setDaemon(true);
            
            //we starten de client
            t.start(); 
            
            //we maken een handler die de berichten van de server zal verwerken (XML Parser?)
            handler = new Handler(); 
            //while(true)
            //    handler.wachtOpBericht();

            //we laten de handler oneindig wachten op antwoord
            //Thread t2 = new Thread(handler);
            //t.setDaemon(true);
            //t.start();
            
        } catch (Exception e) {
            System.out.println("Fout bij Connectie()" + e.getMessage());
            e.printStackTrace();
        }
    }
    
    public void stuurBericht(String bericht) {
        //System.out.println("We proberen te sturen: " + bericht);
        try {
            client.queueTeVerzendenData(bericht.getBytes(), handler);
        } catch (Exception e) {
            System.out.println("Fout bij Connectie.stuurBericht()" + e.getMessage());
            e.printStackTrace();
        }
    }
    
    //functie voor testdoeleinden
    public void wachtEnStuur() {
        try {
            System.out.println("\nWe wachten 15sec en sturen dan terug iets.");
            Thread.currentThread().sleep(15000);
            stuurBericht("Sanka, are ya STILL dead?");
        }
        catch (Exception ex) {
            ex.printStackTrace();
        }
    }
}
